package org.example

import org.apache.spark.SparkConf
import org.apache.spark.streaming.dstream.{DStream, ReceiverInputDStream}
import org.apache.spark.streaming.{Seconds, StreamingContext}


import javax.sound.midi.Receiver

object zye {
def main(args:Array[String]):Unit= {
  val sparkConf = new
      SparkConf().setMaster("local[2]").setAppName("NetWordCount")
  val ssc = new StreamingContext(sparkConf, Seconds(5))
  val dStream: ReceiverInputDStream[String] =
    ssc.socketTextStream("localhost",9999)
  // 词频统计
  val lines: DStream[String] = dStream.flatMap(_.split(" "))
  val wordDStream: DStream[(String,Int)] = lines.map((_,1))
  val result = wordDStream.reduceByKey(_+_)

    result.print()
    ssc.start()
    ssc.awaitTermination()

  }
}
